type google.golang.org/grpc.csAttempt
38 uses
google.golang.org/grpc (current package)
rpc_util.go#L241: after(*callInfo, *csAttempt)
rpc_util.go#L250: func (EmptyCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L284: func (o HeaderCallOption) after(_ *callInfo, attempt *csAttempt) {
rpc_util.go#L306: func (o TrailerCallOption) after(_ *callInfo, attempt *csAttempt) {
rpc_util.go#L328: func (o PeerCallOption) after(_ *callInfo, attempt *csAttempt) {
rpc_util.go#L367: func (o FailFastCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L402: func (o OnFinishCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L426: func (o MaxRecvMsgSizeCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L456: func (o AuthorityOverrideCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L480: func (o MaxSendMsgSizeCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L503: func (o PerRPCCredsCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L531: func (o CompressorCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L556: func (acceptCompressorsCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L593: func (o ContentSubtypeCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L632: func (o ForceCodecCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L672: func (o ForceCodecV2CallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L697: func (o CustomCodecCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L725: func (o MaxRetryRPCBufferSizeCallOption) after(*callInfo, *csAttempt) {}
stream.go#L384: op := func(a *csAttempt) error {
stream.go#L439: func (cs *clientStream) newAttemptLocked(isTransparent bool) (*csAttempt, error) {
stream.go#L490: return &csAttempt{
stream.go#L500: func (a *csAttempt) getTransport() error {
stream.go#L522: func (a *csAttempt) newStream() error {
stream.go#L618: attempt *csAttempt
stream.go#L630: op func(a *csAttempt) error
stream.go#L636: type csAttempt struct {
stream.go#L686: func (a *csAttempt) shouldRetry(err error) (bool, error) {
stream.go#L783: func (cs *clientStream) retryLocked(attempt *csAttempt, lastErr error) error {
stream.go#L816: func (cs *clientStream) withRetry(op func(a *csAttempt) error, onSuccess func()) error {
stream.go#L864: err := cs.withRetry(func(a *csAttempt) error {
stream.go#L916: func (cs *clientStream) replayBufferLocked(attempt *csAttempt) error {
stream.go#L925: func (cs *clientStream) bufferForRetryLocked(sz int, op func(a *csAttempt) error, cleanup func()) {
stream.go#L982: op := func(a *csAttempt) error {
stream.go#L1020: err := cs.withRetry(func(a *csAttempt) error {
stream.go#L1045: op := func(a *csAttempt) error {
stream.go#L1123: func (a *csAttempt) sendMsg(m any, hdr []byte, payld mem.BufferSlice, dataLength, payloadLength int) error {
stream.go#L1147: func (a *csAttempt) recvMsg(m any, payInfo *payloadInfo) (err error) {
stream.go#L1220: func (a *csAttempt) finish(err error) {